package com.wlz.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.messaging.MessagingException;
import org.springframework.stereotype.Component;

import javax.jms.Queue;


/**
 * @author： wlz
 * @Date 2020/8/18 14:41
 * @description： TODO 发送消息
 * @version: 1.0
 */
@Component
@Slf4j
public class PtpSender {

    /**
     * 注入存放消息队列的队列，用于下列方法 一
     */
    @Autowired
    private Queue queue;

    /**
     * 注入springboot 封装的工具类
     */
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    /**
     * 发送消息
     * @param msg
     */
    public void sendMsg(String msg) {
        try {

            jmsMessagingTemplate.convertAndSend(queue,msg);
        } catch (MessagingException e) {
            log.error("sendMsg:",e);
        }
    }

}
